#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""  
@Project : wupeiqi_async
@File : 11-连接单个Redis.py
@Author : Royce
@Time : 2025/7/13 11:51  
@脚本说明 : 
"""
import asyncio
import aioredis


async def execute(address, password):
    print("开始执行", address)

    # 网络IO操作：创建redis连接
    redis = await aioredis.from_url(
        url=address, password=password,  # 独立传参
        db=0, decode_responses=True
    )

    # 网络IO操作：在redis中设置哈希值car，内部在设三个键值对，即： redis = { car:{key1:1,key2:2,key3:3}}
    await redis.hset('car', mapping={'key1': 1, 'key2': 2, 'key3': 3})

    # 网络IO操作：去redis中获取值
    result = await redis.hgetall('car')
    print(f'取出设置的car值：{result}')  # 取出car的值

    # 网络IO操作：关闭redis连接
    await redis.close()

    # 打印程序运行完成标志
    print("结束", address)


if __name__ == '__main__':
    asyncio.run(execute('redis://192.168.88.66:6379', "666888"))
